// package com.lambda.cloud.listener;
//
// import com.lambda.cloud.rocketmq.listener.LambdaRocketMQListener;
// import com.lambda.cloud.rocketmq.message.LambdaMessageView;
// import lombok.RequiredArgsConstructor;
// import lombok.extern.slf4j.Slf4j;
// import org.apache.rocketmq.client.annotation.RocketMQMessageListener;
// import org.apache.rocketmq.client.apis.consumer.ConsumeResult;
// import org.apache.rocketmq.client.apis.message.MessageView;
// import org.springframework.stereotype.Component;
//
// import java.nio.ByteBuffer;
// import java.nio.charset.StandardCharsets;
//
// @Slf4j
// @RocketMQMessageListener(topic = "amapStationInfoChangeTopic", consumerGroup =
// "amapStationStatusChangeConsumerGroup")
// @Component
// @RequiredArgsConstructor
// public class TestTopic2Listener extends LambdaRocketMQListener<String> {
//
//    @Override
//    public ConsumeResult consume(LambdaMessageView<String> messageView) {
//        log.info("ListListener consume message: {}", messageView);
//        return ConsumeResult.SUCCESS;
//    }
//
//    @Override
//    public ConsumeResult consumeError(MessageView messageView, Exception exception) {
//        ByteBuffer body = messageView.getBody();
//        byte[] bytes = new byte[body.remaining()];
//        body.get(bytes);
//        String s = new String(bytes, StandardCharsets.UTF_8);
//        log.error("ListListener consume error: {}", s);
//        return ConsumeResult.SUCCESS;
//    }
// }
